package com.yzw.rabbitmq.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

/**
 * 初始化连接rabbitMQ
 * @author hhj
 *
 */
@Component
public class QueueConfig {
	@Bean
	public Queue getQueue() {
		Queue q = new Queue("mq", true);
		return q;
	}

	@Bean
	public Queue getSecondQueue() {
		Queue q = new Queue("SGAlertQueue", true);
		return q;
	}

}
